# -*coding: utf-8 -*-
# @Time     : 2025/8/21 20:20 
# @Author   : CHUYAO
# @Email    : 1204602307@qq.com
# @File     : __init__.py.py
# @Software : PyCharm
# @Project ：cy_query
# cd opt/kafka/bin
# ./kafka-topics.sh --bootstrap-server localhost:9092 --list 查看所有主题
# ./kafka-topics.sh --bootstrap-server localhost:9092 --create --topic test-topic --partitions 3 --replication-factor 1 创建一个名为 test-topic 的主题，包含3个分区，1个副本
# ./kafka-console-producer.sh --bootstrap-server localhost:9092 --topic test-topic 发送消息
# ./kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test-topic --from-beginning  从头开始消费 test-topic 的所有消息
from cy_query.utils.kafka.base import Kafka, create_signed_token, verify_signed_token
